package com.exd.flink.common;

import org.apache.flink.util.OutputTag;

import com.exd.flink.domain.VDataBean;
import com.exd.flink.domain.VDataErrorBean;

/**
 * 描述: 分流标签
 * 创建人: 赵兴炎
 * 日期: 2022年9月13日
 */
public class OutputVdataTagBase {
	
	/**
	 * BDCM Vcompute 元数据
	 */
	public static OutputTag<String> BDCM_VCOMPUTE = new OutputTag<String>("bdcmVcompute"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vcompute 元数据
	 */
	public static OutputTag<String> VDCM_VCOMPUTE = new OutputTag<String>("vdcmVcompute"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 元数据
	 */
	public static OutputTag<String> BDCM_VDATA = new OutputTag<String>("bdcmVdata"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 元数据
	 */
	public static OutputTag<String> VDCM_VDATA = new OutputTag<String>("VDCM_VDATA"){private static final long serialVersionUID = 1L;};
	
	
	/**
	 * BDCM Vdata 解析正常数据
	 */
	public static OutputTag<VDataBean> BDCM_ANALYTICAL_VDATA_OK = new OutputTag<VDataBean>("BDCM_ANALYTICAL_VDATA_OK"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 解析正常数据
	 */
	public static OutputTag<VDataBean> VDCM_ANALYTICAL_VDATA_OK = new OutputTag<VDataBean>("VDCM_ANALYTICAL_VDATA_OK"){private static final long serialVersionUID = 1L;};
		
	/**
	 * BDCM Vdata 解析异常数据
	 */
	public static OutputTag<VDataErrorBean> BDCM_ANALYTICAL_VDATA_ERROR = new OutputTag<VDataErrorBean>("BDCM_ANALYTICAL_VDATA_ERROR"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 解析异常数据
	 */
	public static OutputTag<VDataErrorBean> VDCM_ANALYTICAL_VDATA_ERROR = new OutputTag<VDataErrorBean>("VDCM_ANALYTICAL_VDATA_ERROR"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 分片数据
	 */
	public static OutputTag<VDataBean> BDCM_VDATA_SHARD = new OutputTag<VDataBean>("BDCM_VDATA_SHARD"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 分片数据
	 */
	public static OutputTag<VDataBean> VDCM_VDATA_SHARD = new OutputTag<VDataBean>("VDCM_VDATA_SHARD"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 全量整包数据
	 */
	public static OutputTag<VDataBean> BDCM_VDATA_PACKAGE_FULL= new OutputTag<VDataBean>("BDCM_VDATA_PACKAGE_FULL"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 事件整包数据
	 */
	public static OutputTag<VDataBean> BDCM_VDATA_PACKAGE_EVENT= new OutputTag<VDataBean>("BDCM_VDATA_PACKAGE_EVENT"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 数采整包数据
	 */
	public static OutputTag<VDataBean> BDCM_VDATA_PACKAGE_MINI= new OutputTag<VDataBean>("BDCM_VDATA_PACKAGE_MINI"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 全量整包数据
	 */
	public static OutputTag<VDataBean> VDCM_VDATA_PACKAGE_FULL= new OutputTag<VDataBean>("VDCM_VDATA_PACKAGE_FULL"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 事件整包数据
	 */
	public static OutputTag<VDataBean> VDCM_VDATA_PACKAGE_EVENT= new OutputTag<VDataBean>("VDCM_VDATA_PACKAGE_EVENT"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 数采整包数据
	 */
	public static OutputTag<VDataBean> VDCM_VDATA_PACKAGE_MINI= new OutputTag<VDataBean>("VDCM_VDATA_PACKAGE_MINI"){private static final long serialVersionUID = 1L;};
	
	/**
	 * BDCM Vdata 全量整包数据索引
	 */
	public static OutputTag<VDataBean> BDCM_VDATA_PACKAGE_FULL_INDEX= new OutputTag<VDataBean>("BDCM_VDATA_PACKAGE_FULL_INDEX"){private static final long serialVersionUID = 1L;};
	
	/**
	 * VDCM Vdata 全量整包数据索引
	 */
	public static OutputTag<VDataBean> VDCM_VDATA_PACKAGE_FULL_INDEX= new OutputTag<VDataBean>("VDCM_VDATA_PACKAGE_FULL_INDEX"){private static final long serialVersionUID = 1L;};
	


}
